//package com.example.websocket.another;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.context.ApplicationListener;
//import org.springframework.data.redis.core.RedisTemplate;
//import org.springframework.data.redis.core.StringRedisTemplate;
//import org.springframework.messaging.simp.SimpMessagingTemplate;
//import org.springframework.messaging.simp.stomp.StompHeaderAccessor;
//import org.springframework.web.socket.messaging.SessionConnectEvent;
//
//
///**
// * 创建一个监听器来获取到websocket的session  不用了 用 WebSocketEventListener
// *
// * @author Administrator
// */
//@Slf4j
//public class StompConnectEventListener implements ApplicationListener<SessionConnectEvent> {
//    @Autowired
//    private StringRedisTemplate stringRedisTemplate;
//
//    @Autowired
//    private SimpMessagingTemplate simpMessagingTemplate;
//
//    @Override
//    public void onApplicationEvent(SessionConnectEvent event) {
//        StompHeaderAccessor sha = StompHeaderAccessor.wrap(event.getMessage());
//        //login get senderFrom browser
//        if (sha.getNativeHeader("id") == null) {
//            log.info("未获取用户唯一标识！");
//            return;
//        }
//        String userId = sha.getNativeHeader("id").get(0);
//        String sessionId = sha.getSessionId();
//        stringRedisTemplate.opsForValue().set("websocket:" + userId, sessionId);
//
//        log.info("用户唯一标识：{}，session 标识：{}", userId, sessionId);
//        notice();
//    }
//
//    public void notice() {
//        Object sessionIds = stringRedisTemplate.keys("websocket:*");
//
//        NotifyBean notifyBean = NotifyBean.builder().content("服务器 Send all persons id！").data(sessionIds).build();
//        simpMessagingTemplate.convertAndSend(notifyBean);
//        simpMessagingTemplate.convertAndSend("/topic/public", notifyBean);
//    }
//}